package cn.doitedu.demo2;

import cn.doitedu.beans.UserAction;
import org.apache.flink.api.common.functions.RuntimeContext;
import org.apache.flink.util.Collector;

import java.io.IOException;

public interface RuleCalculator {

    public void init(RuntimeContext runtimeContext) throws IOException;


    public void calc(UserAction userAction, Collector<String> out) throws IOException;

    public String ruleId();

}
